package com.pig4cloud.pigx.knowledge.support.rule;

import com.pig4cloud.pigx.knowledge.dto.AiMessageResultDTO;
import com.pig4cloud.pigx.knowledge.dto.ChatMessageDTO;
import reactor.core.publisher.Flux;

/**
 * chat 抽象
 *
 * @author lengleng
 * @date 2024/6/3
 */
public interface ChatRule {

	/**
	 * 处理聊天信息
	 * @param chatMessageDTO 聊天上文
	 * @return flux stream
	 */
	default Flux<AiMessageResultDTO> process(ChatMessageDTO chatMessageDTO) {
		return Flux.empty();
	}

}
